package com.framewiki.kafka.client.web.service;

import com.cdkjframework.exceptions.GlobalException;
import com.cdkjframework.kafka.consumer.service.ConsumerService;
import com.cdkjframework.util.log.LogUtils;
import org.springframework.stereotype.Service;

/**
 * @ProjectName: framewiki-kafka
 * @Package: com.framewiki.kafka.client.web.service
 * @ClassName: consumerServiceImpl
 * @Author: xiaLin
 * @Description: Java 类说明
 * @Date: 2024/5/4 23:22
 * @Version: 1.0
 */
@Service
public class ConsumerServiceImpl implements ConsumerService {

  /**
   * 日志
   */
  private final LogUtils logUtils = LogUtils.getLogger(ConsumerServiceImpl.class);

  /**
   * 消息内容
   *
   * @param topics  主题
   * @param message 内容
   * @throws GlobalException 异常信息
   */
  @Override
  public void onMessage(String topics, String message) throws GlobalException {
    logUtils.error("topics：{}，message：{}", topics, message);
  }
}
